* Load balance topics on RabbitMQ nodes

* Replace isOpen() checks by catching AlreadyClosedException

… (#245)

… script (#246)

* [Pulsar] Fix available zone not configured and clean up the terraform script

* Fix wrong output of zookeeper instances

* Support configuring protocol handlers and many other options

* Fix deployment failure for RedHat 8

* Fix protocol handlers not loaded

* Adjust the extra_vars.yaml

* Use the original name of deloy.yaml

* Add document for skip_journal

* Update README

* Support configuring max heap/direct memory

* Update gRPC version for Pravega 0.12.

Signed-off-by: Andrey Koltsov <a99920641@gmail.com>

* Add comment @ pom.xml
Signed-off-by: AndreyKoltsov1997 <a99920641@gmail.com>

* update git repository address
* Cannot create topic with partitions in RabbitMQ, so use 1 partition for rabbitmq

Bumps [jackson-databind](https://github.com/FasterXML/jackson) from 2.9.10.8 to 2.12.6.1.
- [Release notes](https://github.com/FasterXML/jackson/releases)
- [Commits](https://github.com/FasterXML/jackson/commits)

---
updated-dependencies:
- dependency-name: com.fasterxml.jackson.core:jackson-databind
  dependency-type: direct:production
...

Signed-off-by: dependabot[bot] <support@github.com>

Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>

…#259)" (#264)

This reverts commit 800e1af.

…oundError (#266)

Co-authored-by: zhangjidi2016 <zhangjidi@cmss.chinamobile.com>

Co-authored-by: zhangjidi <zhangjidi@cmss.chinamobile.com>

* Fix license check and modify configurations for multi topics test

* Update driver-pulsar/pom.xml

Co-authored-by: Matteo Merli <mmerli@apache.org>

* Fixing infinite loop waiting for consumers to be ready

* Throw an exception when the timeout is raised when waiting for consumers to be ready

Bumps [jetty-server](https://github.com/eclipse/jetty.project) from 9.4.42.v20210604 to 10.0.10.
- [Release notes](https://github.com/eclipse/jetty.project/releases)
- [Commits](jetty/jetty.project@jetty-9.4.42.v20210604...jetty-10.0.10)

---
updated-dependencies:
- dependency-name: org.eclipse.jetty:jetty-server
  dependency-type: direct:production
...

Signed-off-by: dependabot[bot] <support@github.com>

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>

License

Update comment

Spotless

Pass credentials

Remove final

Typo

* Resilient resource creation

# Conflicts:
#	benchmark-framework/src/main/java/io/openmessaging/benchmark/worker/LocalWorker.java
#	driver-api/src/main/java/io/openmessaging/benchmark/driver/BenchmarkDriver.java

Resilient resource creation

# Conflicts:
#	benchmark-framework/src/main/java/io/openmessaging/benchmark/worker/LocalWorker.java
#	driver-api/src/main/java/io/openmessaging/benchmark/driver/BenchmarkDriver.java
#	driver-rabbitmq/deploy/templates/rabbitmq-quorum.yaml

License header

Missing import

spotless

* findbugs exclude

* Pulsar 2.10.2

* More version changes

Co-authored-by: Matteo Merli <mmerli@apache.org>

Bumps [testng](https://github.com/cbeust/testng) from 7.6.1 to 7.7.0.
- [Release notes](https://github.com/cbeust/testng/releases)
- [Changelog](https://github.com/cbeust/testng/blob/master/CHANGES.txt)
- [Commits](testng-team/testng@7.6.1...7.7.0)

---
updated-dependencies:
- dependency-name: org.testng:testng
  dependency-type: direct:development
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>

* Fix failed drive-kop tests

* Fix format violation

* exclude artemis netty transitive dependency

* lint pom.xml

---------

Co-authored-by: sky.kistler <sky.kistler@reddit.com>

* [nats] Add storage type to config

so one can test with file or memory stream.

* [nats] Add maxBytes to config

so one can prevent NATS running out of memory incase the storage type is set to "Memory"

…n-plugin:2.25.0:check (check) on project driver-rocketmq: The following files had format violations: [ERROR] src/main/java/io/openmessaging/benchmark/driver/rocketmq/RocketMQBenchmarkDriver.java' (#399)

Co-authored-by: nuolin <lushiji@xiaohongshu.com>

* Grow the histogram buffer if it is too small

When we serialize a histogram to a byte array, the intermediate
ByteBuffer that we pass may be too small which may result in silent
truncation of the encoded histogram.

This will manifest on the driver side as a decoding failure.

This change detects this case and grows the buffer by a
factor of 2 until it fits.

Fixes #369.

* Add Histogram deserialization test

Add an addition test to the HistogramSerDeTest which tests that
histogram deserialization roundtrips even when the serialized size
exceeds the initial buffer.

* Fixed spotbugs warnings

---------

Co-authored-by: Matteo Merli <mmerli@apache.org>

#394)

Bumps [com.rabbitmq:amqp-client](https://github.com/rabbitmq/rabbitmq-java-client) from 4.8.0 to 5.18.0.
- [Release notes](https://github.com/rabbitmq/rabbitmq-java-client/releases)
- [Commits](rabbitmq/rabbitmq-java-client@v4.8.0...v5.18.0)

---
updated-dependencies:
- dependency-name: com.rabbitmq:amqp-client
  dependency-type: direct:production
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>

…397)

Signed-off-by: Ning Yu <ningyu@automq.com>

Some known issues with current version:
- PEM files cannot be used because of a bug.

* Support set client.id with Zone ID for Kafka driver

* Apply spotless fix

* Updated README.md

* Squash merge feature/update-docker-image into master

* Install vim on the openmessaging image

* Start shell by default

* Start shell by default also for Dockerfile.build

* Use eclipse-temurin:17, fix apt install, and document image tagging\n\n- Switch base images to eclipse-temurin:17 for best practice\n- Remove version pinning for vim/tzdata to avoid apt errors\n- Update README to show -t usage and new image names\n- Prevent dangling images by tagging in build commands

* feat: implement driver-mqtt5

* use actions/upload-artifact@v4 because v3 is deprecated

Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>

* chore: fix code style issues

Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>

* chore: fix line length

Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>

* chore: adapt spotless code format

Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>

* chore: use lambada

Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>

---------

Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>
Co-authored-by: Li Zhanhui <lizhanhui@gmail.com>

* Support RocketMQ5 benchmark using grpc sdk

* chore: update README

Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>

---------

Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>
Co-authored-by: Li Zhanhui <lizhanhui@gmail.com>

#443)

* feat: Add message size distribution support for realistic workload testing (#1)

* plan

* compiles with java 21

* cleanup

* top of range sizes

---------

Co-authored-by: Fab <fabian.haupt@klaviyo.com>